f1e3931bd70fe430150bf4d17a31764bab6d0cd3,hazelcast/src/main/java/com/hazelcast/collection/multimap/tx/TransactionalMultiMapProxySupport.java,TransactionalMultiMapProxySupport,removeInternal,#Data#Data#,103

Before Change


        }
        if (version != -1 || recordId != -1){
            TxnRemoveOperation operation = new TxnRemoveOperation(proxyId, key, recordId, value);
            MultiMapTransactionLog log = (MultiMapTransactionLog)tx.getTransactionLog(getTxLogKey(key));
            if (log != null){
                log.addOperation(operation);
            }
            else {
                log = new MultiMapTransactionLog(key, proxyId, ttl, getThreadId(), version, operation);

After Change


            coll =  createCollection(response.getRecordCollection(getNodeEngine()));
            txMap.put(key, coll);
        } else {
            log = (MultiMapTransactionLog)tx.getTransactionLog(getTxLogKey(key));
        }
        CollectionRecord record = new CollectionRecord(config.isBinary() ? value : getNodeEngine().toObject(value));
        Iterator<CollectionRecord> iterator = coll.iterator();
        long recordId = -1;
        while (iterator.hasNext()){
            CollectionRecord r = iterator.next();
            if (r.equals(record)){
                iterator.remove();
                recordId = r.getRecordId();
                break;
            }
        }
        if (version != -1 || recordId != -1){
            TxnRemoveOperation operation = new TxnRemoveOperation(proxyId, key, recordId, value);
            log.addOperation(operation);
            return recordId != -1;
        }
        return false;